// index.js
/* app.js: 小程序初始化js；
app.json: 小程序配置文件，如：导航，窗口，各页面引入；
app.wxss: 小程序公共样式;
各个页面：
Pages：各个子页面以js+json+wxml+wxss组成，方便管理，右边可快捷生成page; 
Pages：每一个子页面都需要写到这个数组里，其实就是路由引入；
Window：系统配置，包括标题，标题颜色，标题背景等（如果不设置分页面配置则默认全覆盖）；
Tabbar：官方提供的导航功能，可以设置导航栏，list为导航数组，存放导航项、color为字体颜色、selectedcolor为选中颜色、backgroundcolor为背景颜色；
globaldata为全局变量
如果要使用请在对应page.js引入：const app = getApp();*/
//import mqtt from '../../utils/mqtt'

var mqtt1 = require('../../utils/mqtt.min.js')
var client1=null



Page({
  data: {
    id1:'',
    pic:'../tp/t0001.jpg',
    name:'用户名',
    local:'我是注册页面',
    adc:'5677',
    username:"",
    userpws:""
    },
    /*事件处理*/ 
  onLoad(){  
    //this.connectmqtt1()
    this.jianting()
  },
    jianting:function(e){},

    getuser:function(e){
      wx.getUserProfile({
        desc: '用于完善会员资料并绑定账户', // 声明获取用户个人信息后的用途，后续会展示在弹窗中，请谨慎填写
        success: (res) => {
          console.log(res)
          wx.setStorageSync('weiXinMing', res.userInfo.nickName)//同步保存数据
          wx.setStorageSync('weiXinTuPian', res.userInfo.avatarUrl)
        }
      })
    },
    
  connectmqtt1:function(){
    var that=this
    var id=Math.floor(Math.random()*50 + 50) //50到100范围内随机取整数
    var ids=id.toString()
    that.data.id1='shouJI556d'+ids
    const options1 ={
      connectTimeout:4000, //连接延时
      clientId:that.data.id1,   //客户端ID
      port:443,            //WSS协议 端口
      username:'thingidp@alukwqb|usr_4g|0|MD5', //连接用户名
      password:'e5bcd8391cafb0eed8db006f7a376a16'//连接密码
    }
    client1=mqtt1.connect('wxs://alukwqb.iot.gz.baidubce.com/mqtt',options1)
    client1.on('connect',(e)=>{
      console.log('1连接成功')
      client1.subscribe('yonghu_shou',{qos:0},function(err){
        if(!err)
        {console.log('1订阅yonghu_shou成功')}
      })
      /*
      client1.subscribe('yuan_kong',{qos:0},function(err){
        if(!err)
        {console.log('订阅yuan_kong成功')}
      })*/
    })
    //监听
    client1.on('message',function(topic,message){
    console.log('1收到'+message.toString())
    })
    client1.on('reconnect',(error)=>{
      console.log('1重新连接',error)
    })
    client1.on('error',(error)=>{
      console.log('1连接失败',error)
    })
    /*断开
    client1.end()
    */

  },

  username:function(e){ //获取第一个文本用户名,username接收
    if(e.detail.value!="")
    {
      if (!(/^1[3456789]\d{9}$/.test(e.detail.value)))//匹配手机号
      {
        //console.log('不是手机号')
        //this.showMessage('手机号格式不正确')
      }else
      {
        console.log('是手机号')
        this.setData({
          username:e.detail.value
        })
        
      }
    }
  },
  password: function (e) { //获取第二个文本密码，userpws接收
    if (e.detail.value!="") {
      this.setData({
        userpws: e.detail.value
      })
    } else{
      this.setData({
        userpws:""
      })
    }   
  },

  baocun:function(e){
    this.username()
    this.password()
    console.log('保存数据')
    wx.setStorageSync('mc', this.data.username)
    wx.setStorageSync('ma', this.data.userpws)
  },
  denglu:function(e){
   //const asd =wx.getStorageSync('mc') //同步获取本地数据
   //const asf =wx.getStorageSync('ma') //同步获取本地数据
   if(this.data.username!="" && this.data.userpws!="")
   {
    client1.publish('fuwuqi','asd',function(err){
      if(!err)
      {
        console.log(asd)
      }
    })
   }    
  },
  zhuce:function(e){
    if(this.data.username!="" && this.data.userpws!="")
    {
     client1.publish('fuwuqi','asd',function(err){
       if(!err)
       {
         console.log(asd)
       }
     })
    }
  }

  


})
